package org.example.model;

import lombok.Data;
import java.util.Map;

@Data
public class CdcMessage {
    // 数据库名
    private String database;
    
    // 表名
    private String table;
    
    // 操作类型：INSERT, UPDATE, DELETE
    private String operationType;
    
    // 变更前的数据
    private Map<String, Object> before;
    
    // 变更后的数据
    private Map<String, Object> after;
    
    // 时间戳
    private Long ts;
} 